3bcd7bf2018401dd4da4fcb9921666da82af79a2,wildfly-jberet-samples/camelReaderWriter/src/main/java/org/jberet/samples/wildfly/camelReaderWriter/CamelJobResource.java,CamelJobResource,jobExecutionRestart,#UriInfo#String#,241
Before Change
final Properties jobParams = new Properties();
jobParams.setProperty("fail", "false");
final ProducerTemplate producerTemplate = camelContext.createProducerTemplate();
producerTemplate.setDefaultEndpointUri(getJBeretComponentUri(uriInfo, null));
final long restartJobExecutionId = producerTemplate.requestBody(jobParams, long.class);
producerTemplate.stop();
return restartJobExecutionId;
}
@Path("jobexecutions/{jobExecutionId}/abandon")
After Change
final @PathParam("jobExecutionId") String jobExecutionId) throws Exception {
final Properties jobParams = new Properties();
jobParams.setProperty("fail", "false");
return requestBody(getJBeretComponentUri(uriInfo, null), jobParams, long.class);
}
@Path("jobexecutions/{jobExecutionId}/abandon")